package 网络编程.tcp协议通信;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

public class 服务端接收线程 extends Thread {
    public Socket 通信管道;

    public 服务端接收线程(Socket 通信管道) {
        this.通信管道 = 通信管道;
    }

    @Override
    public void run() {
        try {
            InputStream 字节输入流=通信管道.getInputStream();
            DataInputStream 数据输入流=new DataInputStream(字节输入流);
            while(true){
                try {
                    String 数据 = 数据输入流.readUTF();
                    System.out.println(数据);
                } catch (Exception e) {
                    System.out.println(通信管道.getRemoteSocketAddress()+"下线了");
                    数据输入流.close();
                    通信管道.close();
                    break;
                }
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}
